-
Notifications
You must be signed in to change notification settings - Fork 345
feat(transaction): RewriteFilesAction + Validation Support + Process Delete Manifests
#1606
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: main
Are you sure you want to change the base?
Conversation
|
|
||
| for entry in manifest.entries() { | ||
| match entry.content_type() { | ||
| DataContentType::Data => { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
These are the exact same code blocks? So why does the ManifestEntry's DataContentType matter? Why not just do:
for entry in manifest.entries() {
if snapshot_producer
.deleted_data_files
.iter()
.any(|f| f.file_path == entry.data_file.file_path())
{
delete_entries.push(copy_with_deleted_status())
}
}There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It looks very similar with one little difference: one block iterates thru deleted_data_files and another iterates thru deleted_delete_files
71a696f to
336c974
Compare
Which issue does this PR close?
RewriteFilessupport to iceberg-rust #1607What changes are included in this PR?
RewriteFilesActionSnapshotValidatorand implemented it forRewriteFilesOperationSnapshotProducerand generate manifestsAre these changes tested?
Not tested so far